package com.lemon.cloud.websocket.distribute;

import cn.hutool.json.JSONUtil;
import com.lemon.cloud.websocket.message.MessageDO;
import lombok.AllArgsConstructor;
import org.springframework.data.redis.core.RedisTemplate;

@AllArgsConstructor
public class RedisMessageDistributor implements MessageDistributor {
    private final RedisTemplate<String,String> redisTemplate;

    @Override
    public void distribute(MessageDO messageDO) {
        String str = JSONUtil.toJsonStr(messageDO);
        redisTemplate.convertAndSend(MessageDistributor.DISTRIBUTOR_KEY, str);
    }

}
